package cn.yma.bus.annotation;

import java.lang.annotation.*;

/**
 * 消息订阅
 */
@Documented
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface MessageSubscribe {

    /**
     * 主题
     */
    String topic() default "";

    /**
     * 多主题订阅
     */
    String[] topics() default {};
}
